package com.sbp.message.consumer;

/**
 * Created by wangmin on 2019/4/19.
 */
public abstract class KafkaBaseConsumerThread implements Runnable {
    protected volatile boolean isRun = true;

    public abstract String threadName();
    public abstract void shutdown();
}
